package com.boarsoft.boar.batch.demo.flow.bigfile;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.boarsoft.flow.core.bean.JoinHandler;

/**
 * @ClassName: LoadDpfm01Join   
 * @Description:  分线程装载完成后处理
 */
public class LoadDpfm01Join implements JoinHandler {
	private static final Logger log = LoggerFactory.getLogger(LoadDpfm01Join.class);

	@Override
	public Object join(Object flowData, Map<String, Object> resultMap) {
			
		System.out.println("加载dpfm01共耗时：" + (System.currentTimeMillis() - LoadDpfm01Fork.loadDpfm01ForkStart) + "ms.");
		return resultMap;
	}
}
